package com.efast.cafe.commponent.es.socketio.listener;

import java.io.Serializable;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;


import com.corundumstudio.socketio.SocketIOClient;
import com.efast.cafe.commponent.es.socketio.util.SocketIOUtil;
/**
 * 服务端主动断开socket连接，客户端在建立连接的时候创建redis监听
 * @author fxm
 *
 */
public class DisSocketConnectListener implements MessageDelegate{

	@Override
	public void handleMessage(String message, String channel) {
		SocketIOClient client = SocketIOUtil.getSocketIOClient(message);
		if(client!=null){
			client.disconnect();
		}
	}

}
